c5f7e229cb34a3cda7395670722da1329cf95b3e,src/main/java/net/hasor/rsf/center/server/manager/ServiceManager.java,ServiceManager,requestProviders,#InterAddress#String#String#,488

Before Change


    /** 请求Center�一次全�推� */
    public Result<Boolean> requestProviders(InterAddress rsfAddress, String registerID, String serviceID) {
        // .�新计算ObjectID,并且校验registerID有效性。
        Result<String> objectIDResult = this.checkAndEvalObjectID(rsfAddress, registerID, serviceID);
        String oriObjectKey = null;
        if (!objectIDResult.isSuccess()) {
            ResultDO<Boolean> result = new ResultDO<Boolean>();
            result.setSuccess(false);
            result.setResult(false);
            result.setErrorInfo(objectIDResult.getErrorInfo());
            return result;
        } else {
            oriObjectKey = objectIDResult.getResult();
        }
        //
        // .刷新更新时间

After Change


        //
        // .检查registerID是�为订阅者
        Result<ObjectDO> consumerResult = this.dataAdapter.queryObjectByID(registerID);
        if (consumerResult == null || !consumerResult.isSuccess() || consumerResult.getResult() == null) {
            return buildFailedResult(consumerResult);
        }
        if (!StringUtils.equals(RsfCenterConstants.Center_DataKey_Consumer, consumerResult.getResult().getType())) {
            ResultDO<Boolean> result = new ResultDO<Boolean>();
            result.setErrorInfo(ErrorCode.ServiceTypeFailed_Error);
            result.setSuccess(false);
            return result;
        }